package com.cfwx.db.jdbc;

//PreparedStatement批量处理和事务代码如下：  
import java.sql.Connection;  
import java.sql.PreparedStatement;  
import java.sql.SQLException;  

/* 
64. * PreparedStatement: 
65. 1.addBatch() 将一组参数添加到 PreparedStatement对象内部 
66. 2.executeBatch() 将一批参数提交给数据库来执行，如果全部命令执行成功，则返回更新计数组成的数组。 
67. *  
68. */  
public class PreparedStatementCommitAndRollbackTest {  
    public static void main(String args[]) {  
        Connection con = null;  
        PreparedStatement pstm = null;  
  
       try {  
            // 1. 建立与数据库的连接  
           con = JdbcUtil.getConnection();  
            // 2. 执行sql语句  
           // 1).先创建PreparedStatement语句(发送slq请求）：  
            pstm = con.prepareStatement("insert into student values(?,?,?)");  
            con.setAutoCommit(false);//1,首先把Auto commit设置为false,不让它自动提交  
            // 2) 设置sql语句1  
            pstm.setInt(1, 33);  
            pstm.setString(2,"wangqin");  
            pstm.setString(3, "33");  
          
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。  
            pstm.addBatch();  
           // 2) 设置sql语句2  
            pstm.setInt(1, 34);  
            pstm.setString(2,"wuytun");  
            pstm.setString(3, "c");  
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。  
            pstm.addBatch();  
           // 2) 设置sql语句3  
            pstm.setInt(1, 31);  
            pstm.setString(2,"tetet");  
            pstm.setString(3, "c++");  
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。  
            pstm.addBatch();  
            // 2) 设置sql语句4  
            pstm.setInt(1, 32);  
            pstm.setString(2,"liug");  
            pstm.setString(3, "c");  
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。  
            pstm.addBatch();  
            // 4) 将一批参数提交给数据库来执行，如果全部命令执行成功，则返回更新计数组成的数组。  
            pstm.executeBatch();  
            System.out.println("插入成功！");  
            // 若成功执行完所有的插入操作，则正常结束  
            con.commit();//2,进行手动提交（commit）  
            System.out.println("提交成功!");  
            con.setAutoCommit(true);//3,提交完成后回复现场将Auto commit,还原为true,  
            pstm.close();
        } catch (SQLException e) {  
            e.printStackTrace();  
            try {  
               // 若出现异常，对数据库中所有已完成的操作全部撤销，则回滚到事务开始状态  
               if(!con.isClosed()){  
                    con.rollback();//4,当异常发生执行catch中SQLException时，记得要rollback(回滚)；  
                   System.out.println("插入失败，回滚！");  
                   con.setAutoCommit(true);  
                }  
            } catch (SQLException e1) {  
                e1.printStackTrace();  
            }  
        }finally{  
        	
        	JdbcUtil.closeConnection(con);  
        }  
   }  
}  
